#include "JsiPromises.h"

namespace RNJsi {
JsiPromises::Promise::Promise(jsi::Runtime &rt, jsi::Function resolve, jsi::Function reject)
    : runtime_(rt), resolve_(std::move(resolve)), reject_(std::move(reject))
{}

void JsiPromises::Promise::resolve(const jsi::Value &result)
{
    resolve_.call(runtime_, result);
}

void JsiPromises::Promise::reject(const std::string &message)
{
    jsi::Object error(runtime_);
    error.setProperty(runtime_, "message", jsi::String::createFromUtf8(runtime_, message));
    reject_.call(runtime_, error);
}

jsi::Value JsiPromises::createPromiseAsJSIValue(jsi::Runtime &rt, PromiseSetupFunctionType &&func)
{
    jsi::Function JSPromise = rt.global().getPropertyAsFunction(rt, "Promise");
    jsi::Function fn = jsi::Function::createFromHostFunction(rt, jsi::PropNameID::forAscii(rt, "fn"), 2,
        [func = std::move(func)](jsi::Runtime &rt2, const jsi::Value &thisVal, const jsi::Value *args, size_t count) {
            jsi::Function resolve = args[0].getObject(rt2).getFunction(rt2);
            jsi::Function reject = args[1].getObject(rt2).getFunction(rt2);
            auto wrapper = std::make_shared<Promise>(rt2, std::move(resolve), std::move(reject));
            func(rt2, wrapper);
            return jsi::Value::undefined();
        });

    return JSPromise.callAsConstructor(rt, fn);
}
} // namespace RNJsi
